/** @format */

import { TsReader, TsEvent, TsReaderStatus } from './TsReader';

const reader = new TsReader();

reader.subjectEsPacket.subscribe({
    next: (value: TsEvent) => {
        console.log(value);
    },
});

reader.subjectStatus.subscribe({
    next: (value: TsReaderStatus) => {
        console.log(value);
    },
});

setInterval(() => {
    reader.appendFiles([
        '/home/gj027/Disk/www/record/stream_1/20200114/20200114140002/stream_1-20200114141547-18638.ts',
    ]);
}, 3000);
